package com.xxk.rocket.star.core.message;

import com.alibaba.rocketmq.common.message.Message;
import com.xxk.rocket.star.core.context.ProducerContext;

public interface IProcessMessageProducer {

  //正常继续
  int SUCCESS = 0;
  //不理会后面的处理器直接发送消息
  int SEND = 1;
  //中断发送
  int BREAK = 2;

  int processProducer(ProducerContext producerContext, Message message, Object[] args)
          throws Throwable;

}
